package dk.almbrand.microservice.kafka.consumer.thread;

import dk.almbrand.microservice.exception.SystemException;
import dk.almbrand.microservice.kafka.consumer.ConsumerDaemon;

public interface ConsumerThreadController {
    public void stop();
    public void start(ConsumerDaemon consumer) throws SystemException;
}
